package com.asiainfo.dacp.datastash.broker.redis;

import com.asiainfo.dacp.datastash.broker.core.BrokerContext;

public class RedisConstant {

	public final static String FLOW = "datastash:unit_flow";
	 
	public final static String UNIT_WAIT_QUEUE = "datastash:unit_wait_queue";
	
	public final static String TASK_WAIT_QUEUE = "datastash:unit_task_wait_queue";

	public final static String BROKER_CURRENT_WORK_QUEUE_KEY = "datastash:broker_"+ BrokerContext.getInstance().getBrokerId()+"_work_queue"; 

	public final static String BROKER_WORK_QUEUE_KEY = "datastash:broker_%s_work_queue"; 
	
}
